package pipe

import (
	"fur/src/dbs"
	"log"
)

// 获取数据
func ReadyData(sql string, entity interface{}, args ...interface{}) C {
	out := make(C)
	go func() {
		defer close(out)
		e := &entity
		db := dbs.Orm.Raw(sql, args).Find(e)
		if db.Error != nil {
			log.Println(db.Error)
		}
		out <- e
	}()
	return out
}

//// 获取数据
//func GetData(in C) C{
//	out:=make(C)
//	go func() {
//		defer close(out)
//		for v:=range in{
//
//		}
//		out <- e
//	}()
//	return out
//}
//
//// 操作数据
//func DoData(in C) C{
//	out:=make(C)
//	go func() {
//		defer close(out)
//		for d:=range in{
//			fmt.Println(d)
//			e:=&entity
//			db:= dbs.Orm.Raw(sql,args).Find(e)
//			if db.Error!=nil{
//				log.Println(db.Error)
//			}
//			fmt.Sprintf("%d,%d,%d\n",db.RowsAffected,time.Now())
//			out<-e
//		}
//	}()
//	return out
//}
